Micron Document
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| SparkN0de-git | SparkN0de |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Node / ReticulumProjects / LXMF.git / commits / d97c4f2


Commit d97c4f292e43dfe49b91fb457dab13ded15e9947

󰉖 Browse tree at this commit

Parents : 2d175a3
Author : Mark Qvist <mark@unsigned.io>
Date : 2025-01-14T21:32:10+01:00

Fixed missing checks for file corruption

Changes

1 files changed, 10 insertions(+), 0 deletions(-)

M LXMF/LXMRouter.py +10

Diff

diff --git a/LXMF/LXMRouter.py b/LXMF/LXMRouter.py
index 5410a54..64677a8 100644
--- a/LXMF/LXMRouter.py
+++ b/LXMF/LXMRouter.py
@@ -145,6 +145,9 @@ class LXMRouter:
data = locally_delivered_file.read()
locally_delivered_file.close()
self.locally_delivered_transient_ids = msgpack.unpackb(data)
+ if not type(self.locally_delivered_transient_ids) == dict:
+ RNS.log("Invalid data format for loaded locally delivered transient IDs, recreating...", RNS.LOG_ERROR)
+ self.locally_delivered_transient_ids = {}
except Exception as e:
RNS.log("Could not load locally delivered message ID cache from storage. The contained exception was: "+str(e), RNS.LOG_ERROR)
@@ -156,6 +159,10 @@ class LXMRouter:
data = locally_processed_file.read()
locally_processed_file.close()
self.locally_processed_transient_ids = msgpack.unpackb(data)
+ if not type(self.locally_processed_transient_ids) == dict:
+ RNS.log("Invalid data format for loaded locally processed transient IDs, recreating...", RNS.LOG_ERROR)
+ self.locally_processed_transient_ids = {}
+
except Exception as e:
RNS.log("Could not load locally processed message ID cache from storage. The contained exception was: "+str(e), RNS.LOG_ERROR)
@@ -175,6 +182,9 @@ class LXMRouter:
with open(self.storagepath+"/outbound_stamp_costs", "rb") as outbound_stamp_cost_file:
data = outbound_stamp_cost_file.read()
self.outbound_stamp_costs = msgpack.unpackb(data)
+ if not type(self.outbound_stamp_costs) == dict:
+ RNS.log("Invalid data format for loaded outbound stamp costs, recreating...", RNS.LOG_ERROR)
+ self.outbound_stamp_costs = {}
self.clean_outbound_stamp_costs()
self.save_outbound_stamp_costs()


──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────